package cn.lsh.kafka.deserializer;

import cn.lsh.kafka.db.entity.OffsetEntity;
import org.apache.kafka.common.serialization.Deserializer;

public class OffsetDeserializer implements Deserializer<OffsetEntity> {
	@Override
	public OffsetEntity deserialize(String topic, byte[] bytes) {
		String s = new String(bytes);
		return null;
	}
}
